package com.xxwu.messagequeue.common.argumentsType;

import lombok.Data;

import java.io.Serializable;
@Data
public class BasicConsumerArguments extends BasicArguments implements Serializable {
    private String consumerTag;
    private String queueName;
    private boolean autoAck;
    // 这里的 consumer 是一个函数式接口，用来传递消费者处理消息的方式
    // 但方法在网络通信中无法传输
    // 所以在服务器这边都使用同样的 consumer 方法对消息进行处理——将消息返回给客户端
    // 所以这里不需要这个参数
//    Consumer consumer
}
